package com.gaofans.nrpc.common.processor;

/**
 *
 * @author GaoFans
 * @param <T>
 */
public interface EventListener<T> {

    /**
     * 收到
     * @param chunk
     */
    void onDataChunk(T chunk);

    /**
     * 结束
     */
    void processComplete();

    /**
     * 出错
     * @param e
     */
    void processError(Throwable e);

}
